package com.example.common.grpc;

import com.example.game.proto.internal.SrvResp;
import io.grpc.stub.StreamObserver;
import lombok.extern.slf4j.Slf4j;

/**
 * @author: Allen
 * @create: 2025/7/4 10:56
 * @description:
 **/
@Slf4j
public class DefaultResponseObserverResp implements StreamObserver<SrvResp> {
    @Override
    public void onNext(SrvResp srvResp) {

    }

    @Override
    public void onError(Throwable throwable) {
        if (throwable != null) {
            log.error("===GRPC远程调用异常{}===", throwable.getMessage());
        }
    }

    @Override
    public void onCompleted() {

    }
}
